package com.example.demoexample.operate;

import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import rx.Observable;
import rx.Subscriber;

public class ObservableTest {

    public void test(){
        //被观察者
//        Observable novel=Observable.create();



    }





}
